package com.apex.flink.batch;

import com.apex.flink.FlinkBaseTransform;
import com.apex.flink.FlinkEnvironment;
import org.apache.flink.api.java.DataSet;

public interface FlinkBatchTransform<IN,OUT> extends FlinkBaseTransform {
    DataSet<OUT> processBatch(FlinkEnvironment env, DataSet<IN> data);
}
